/*
muduo网络库给用户提供了两个主要的类
TcpServer : 用于编写服务器程序的
TcpClient : 用于编写客户端程序的

epoll + 线程池
好处：能够把网络I/O的代码和业务代码区分开
给我暴露的结构：用户的链接和断开   用户的可读写事件
*/
#include <muduo/net/TcpServer.h>
#include <muduo/net/EventLoop.h>
#include <iostream>
#include <string>
#include <functional>

using namespace std;
using namespace muduo;
using namespace muduo::net;
using namespace std::placeholders;
/* 基于muduo网络库开发服务器程序
1.组合TcpServer对象
2.创建EventLoop事件循环对象的指针
3.明确TcpServer构造函数需要什么参数，输出ChatServer的构造函数
4.在当前服务器类的构造函数当中，注册处理连接的回调函数和处理读写时间的回调函数
5.设置合适的服务端线程数量，muduo库会自己分配I/O线程和worker线程
*/
class ChatServer
{
public:
    ChatServer(EventLoop *loop,               // 事件循环
               const InetAddress &listenAddr, // Ip + Port
               const muduo::string &nameArg)  // 服务器的名称
        : _server(loop, listenAddr, nameArg), _loop(loop)
    {
        // 给服务器组成用户链接的创建和回调
        _server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1)); // 参数占位符：我除了this指针和还有一个参数

        // 给服务器组成用户读写事件回调
        _server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));

        // 设置服务器端的线程数量  一个IO线程，3个work线程
        _server.setThreadNum(4);
    }

    // 开启时间循环
    void start()
    {
        _server.start();
    }

private:
    // 关注给TcpServer，这个两个回调函数
    // 专门处理用户的连接创建和断开 epoll listenfd accept
    void onConnection(const TcpConnectionPtr &conn) // 这里会有个this指针，导致跟人家的callback类型不同，所以用绑定器
    {

        if (conn->connected())
        {
            cout << conn->peerAddress().toIpPort() << "->" << conn->localAddress().toIpPort() << " satrt:online" << endl;
        }
        else
        {
            cout << conn->peerAddress().toIpPort() << "->" << conn->localAddress().toIpPort() << " satrt:offline" << endl;
            conn->shutdown();// close(fd)
            // loop_>quit();// 服务器退出
        }
    }

    // 专门处理用户的读写事件的
    void onMessage(const TcpConnectionPtr &conn, // 连接
                   Buffer *buffer,                 // 缓冲区
                   Timestamp time)                // 接收到数据的时间新形象
    {
        muduo::string buf = buffer->retrieveAllAsString();
        cout <<" recv data:"  << buf << " time: " << time.toString() << endl;
        conn->send(buf);
    }
    TcpServer _server; // #1
    EventLoop *_loop;  // #2
};

int main()
{
    EventLoop loop; // epoll
    InetAddress addr("127.0.0.1",8080);
    ChatServer server(&loop,addr,"ChatServer");

    server.start();// listenfd epool_ctl->epoll
    loop.loop();// epoll_wait以阻塞方式等待新用户链接，已连接用户读写事件等

    return 0;
}